import time

from pyspark.sql import *

if __name__ == "__main__":
    spark = SparkSession \
        .builder \
        .appName("PlanSpark") \
        .master("local[2]") \
        .getOrCreate()

    survey_raw_df = spark.read \
        .option("header", "true") \
        .option("inferSchema", "true") \
        .csv("./data/plans.csv")
    survey_raw_df.show()
    # time.sleep(1000*1000)
    spark.stop()